package com.powernode.ssm.config;

import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class RabbitMQConfig {

    // 原有的短信队列
    public static final String SMS_QUEUE = "sms.notification.queue";

    // 新增：邮件通知队列
    public static final String EMAIL_NOTIFICATION_QUEUE = "email.notification.queue";

    // 原有的短信队列 Bean
    @Bean
    public Queue smsQueue() {
        return new Queue(SMS_QUEUE, true); // 持久化
    }

    // 新增：邮件通知队列 Bean
    @Bean
    public Queue EmailNotificationQueue() {
        return new Queue(EMAIL_NOTIFICATION_QUEUE, true); // 持久化
    }
}